package com.apex.flink.batch;

import com.apex.flink.FlinkBaseSource;
import com.apex.flink.FlinkEnvironment;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.typeutils.RowTypeInfo;


public interface FlinkBatchSource<T> extends FlinkBaseSource {
    DataSet<T> getData(FlinkEnvironment env);
}
